package com.test.springboot.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author chenxubing
 * @version $Id: UserStreams.java, v 0.1 2018-11-09 3:22 PM chenxubing Exp $$
 */
public interface UserStreams {
    String INPUT = "user-in";
    String OUTPUT = "user-out";

    @Input(INPUT)
    SubscribableChannel inputChannel();

    @Output(OUTPUT)
    MessageChannel outputChannel();
}